package xin.marcher.module.common.constants;

/**
 * RocketMQ 常量类
 */
public class RocketMqConstant {

    /**
     * 商品修改的内部消息topic
     */
    public static final String PRODUCT_UPDATE_TOPIC = "product_update_topic";

    /**
     * 考核结果通知topic
     */
    public static final String INTERIOR_ITEM_EXPRI_RESULT_TOPIC = "interior_item_expri_result_topic";

    /**
     * 默认的producer分组
     */
    public static final String ORDER_DEFAULT_PRODUCER_GROUP = "product_default_producer_group";

    /**
     * 默认的consumer分组
     */
    public static final String PRODUCT_DEFAULT_CONSUMER_GROUP = "product_default_consumer_group";

    /**
     * 监听数据变更consumer分组
     */
    public static final String DATA_CHANGE_CONSUMER_GROUP = "data_change_consumer_group";

    /**
     * 考核结果consumer分组
     */
    public static final String ITEM_EXPRI_RESULT_CONSUMER_GROUP = "item_expri_result_consumer_group";

    /**
     * 数据外部消息变更consumer分组
     */
    public static final String DATA_EXTERNAL_CHANGE_CONSUMER_GROUP = "data_external_change_consumer_group";

    /**
     * 商品修改的consumer分组
     */
    public static final String PRODUCT_UPDATE_CONSUMER_GROUP = "product_update_consumer_group";

    /**
     * 商品修改的consumer分组
     */
    public static final String SURVEY_TASK_UPDATE_CONSUMER_GROUP = "survey_task_update_consumer_group";

    /**
     * 品控问题商品调查单数据变更consumer分组
     */
    public static final String SURVEY_TASK_CHANGE_TOPIC = "survey_task_update_consumer_group";

    /**
     * 品控商品调查单数据变更topic
     */
    public static final String INTERIOR_ITEM_QUALITY_SURVEY_TASK_TOPIC = "interior_item_quality_survey_task_topic";
    /**
     * 监听binlog的topic
     */
    public static final String DATA_CHANGE_TOPIC = "data_change_topic";

    /**
     * 热点缓存广播模式处理本地缓存
     */
    public static final String DATA_HOT_RADIO_TOPIC = "data_hot_radio_topic";

    /**
     * 内部消息处理完成后的回调消息topic
     */
    public static final String DATA_EXTERNAL_CHANGE_TOPIC = "data_external_change_topic";
    /**
     * 缓存变更的消息处理器
     */
    public static final String DATA_MESSAGE_CACHE_TOPIC = "data_message_cache_topic";
    /**
     * 缓存变更的消息处理器
     */
    public static final String DATA_MESSAGE_CACHE_CONSUMER_GROUP = "data_message_cache_consumer_group";

    /**
     * 库存的consumer分组
     */
    public static final String INVENTORY_CONSUMER_GROUP = "inventory_consumer_group";

    /**
     * 分桶下线 consumer分组
     */
    public static final String BUCKET_OFFLINE_GROUP = "bucket_offline_group";

    /**
     * 分桶库存扩容 consumer分组
     */
    public static final String BUCKET_CAPACITY_GROUP = "bucket_capacity_group";

    /**
     * 库存明细保存 consumer分组
     */
    public static final String INVENTORY_DETAIL_GROUP = "inventory_detail_group";

    /**
     * 库存预警 consumer分组
     */
    public static final String WARNING_INVENTORY_GROUP = "warning_inventory_group";

    /**
     * 清除分桶 consumer分组
     */
    public static final String BUCKET_CLEAR_GROUP = "bucket_clear_group";

    /**
     * 刷新本地缓存 consumer分组
     */
    public static final String REFRESH_CACHE_GROUP = "refresh_cache_group";

    /**
     * 同步本地缓存 consumer分组
     */
    public static final String SYNC_REFRESH_CACHE_GROUP = "sync_refresh_cache_group";
    /**
     * 分桶下线 topic
     */
    public static final String BUCKET_OFFLINE_TOPIC = "bucket_offline_topic";

    /**
     * 分桶缓存刷新 topic
     */
    public static final String BUCKET_CACHE_REFRESH_TOPIC = "bucket_cache_refresh_topic";
    /**
     * 分桶库存扩容 topic
     */
    public static final String BUCKET_CAPACITY_TOPIC = "bucket_capacity_topic";

    /**
     * 库存明细保存 topic
     */
    public static final String INVENTORY_DETAIL_TOPIC = "inventory_detail_topic";
    /**
     * 库存预警 topic
     */
    public static final String WARNING_INVENTORY_TOPIC = "warning_inventory_topic";

    /**
     * 清除分桶 topic
     */
    public static final String BUCKET_CLEAR_TOPIC = "bucket_clear_topic";

    /**
     * 卖家缓存预热group
     */
    public static final String PREHEAT_SELLER_CACHE_BUCKET_GROUP = "preheat_seller_cache_bucket_topic";

    /**
     * 卖家缓存预热topic
     */
    public static final String PREHEAT_SELLER_CACHE_BUCKET_TOPIC = "preheat_seller_cache_bucket_topic";

    /**
     * 数据溯源消息topic
     */
    public static final String PRODUCT_TRACE_TOPIC = "product_trace_topic";

    /**
     * 数据溯源消息consumer分组
     */
    public static final String PRODUCT_TRACE_CONSUMER_GROUP = "product_trace_consumer_group";
}
